d4076a41d292e7967e00f211bf6926a87a744b35,tests/frontend/org/voltcore/network/TestNIOWriteStream.java,TestNIOWriteStream,testLastWriteDelta,#,344
Before Change
final ByteBuffer b = ByteBuffer.allocate(5);
wstream.enqueue(b.duplicate());
assertEquals( 5, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
wstream.drainTo( channel, wstream.swapAndSerializeQueuedWrites(pool));
assertEquals( 0, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
Thread.sleep(20);
After Change
}
public void testLastWriteDelta() throws Exception {
final MockChannel channel = new MockChannel(MockChannel.SINK);
MockPort port = new MockPort();
NIOWriteStream wstream = new NIOWriteStream(port);
assertEquals( 0, wstream.calculatePendingWriteDelta(999));
EstTimeUpdater.update(System.currentTimeMillis());
/**
* Test the basic write and drain
*/
final ByteBuffer b = ByteBuffer.allocate(5);
wstream.enqueue(b.duplicate());
assertEquals( 5, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
wstream.swapAndSerializeQueuedWrites(pool);
wstream.drainTo( channel);
assertEquals( 0, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
Thread.sleep(20);